package org.niit.app

import org.apache.spark.streaming.dstream.DStream
import org.niit.bean.Answer
import org.niit.common.TApp
import org.niit.controller.EDUDataController
import org.niit.handler.DataHandler

/**
 * Date:2025/6/11
 * Author：Ys
 * Description:
 */
object EDURealTimeApp extends TApp{

  val eduDataController =  new EDUDataController()
  start("local[*]","EDUApp"){

    val data: DStream[Answer] = DataHandler.kafkaAnswerDataHandler("BD2", "edu")

    eduDataController.dispatch(data)

    DataHandler.startAndAwait()

  }

}
